package com.kafka.service.carMsg.impl;


import com.kafka.service.carMsg.MsgObserver;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 * @descriptions: 转发消息至websocket
 * @author: yunqiang
 * @date: 2022/1/5 15:58
 */
@Component
@Slf4j
public class SendMsgWebsocket implements MsgObserver {

    @Override
    public void send(String message) {
        log.info("websocket发送消息为：" + message);
    }
}
